package cn.doitedu.day05

import cn.doitedu.day01.utils.SparkUtil

/**
 * @Date 22.4.3
 * @Created by HANGGE
 * @Description
 */
object A02_行动算子_Take {
  def main(args: Array[String]): Unit = {
    val sc = SparkUtil.getSc
    val words = sc.textFile("data/a.txt").flatMap(_.split("\\s+"))

    val rdd2 = sc.parallelize(List(6, 8, 1, 2, 3, 4, 5))
    // 行动算子  从角标位置获取响应个数的数据
    // 部分
    val res = rdd2.take(3)

    // 获取有序的数据  shuffle
    val rdd3 = rdd2.sortBy(e => e, false)
    val res2 = rdd3.take(3)
    println(res2.toList)

  }

}
